package com.lightbend.akka.ddata

import akka.actor.{Actor, ActorLogging}
import akka.cluster.ddata.Replicator.ReplicaCount
import com.lightbend.akka.ddata.ReplicatedCache._

class Receiver extends Actor with ActorLogging {

  override def receive: Receive = {

    case ReplicaCount(size) =>
      log.debug(s"==> replicators has $size...")

    case Cached(key, value) =>
      log.debug(s"==> key[$key] -> value[$value]")
  }
}
